package com.gitee.ed.example.reactor;

import reactor.core.publisher.FluxSink;

/**
 * @author hongda.li
 */
@FunctionalInterface
public interface FluxEmitter<T> {

    /**
     * 发射任意数量的信号
     *
     * @param sink 信号
     */
    void emit(FluxSink<T> sink);
}
